package com.cn.broker;

import com.cn.remote.ChannelListener;
import io.netty.channel.ChannelHandlerContext;

public class ClientHouseChannelListener implements ChannelListener {

    private BrokerController brokerController;

    public ClientHouseChannelListener(BrokerController brokerController) {
        this.brokerController = brokerController;
    }

    @Override
    public void registerEvent(ChannelHandlerContext ctx) {

    }

    @Override
    public void unregisterEvent(ChannelHandlerContext ctx) {
        this.brokerController.getConsumerManager().unregister(ctx.channel());
    }
}
